package com.mobileshop.activemq;

import java.io.Serializable;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ReceiveResolver implements com.jfinal.ext.plugin.jms.ReceiveResolver{
	Lock lock=new ReentrantLock();
	public void resolve(Serializable objectMessage) throws Exception {
		lock.lock();
		System.out.println(objectMessage);
		lock.unlock();
	}
}
